package main

import (
	"fmt"

	"github.com/garyburd/redigo/redis"
)

type redis_var struct {
	//连接句柄
	c redis.Conn
	//连接状态
	c_status int
	//错误状态
	err error
}

type Redis_op interface {
	//连接数据库
	iot_redis_connect()
	//写入数据库
	iot_redis_set(key string, msg string)
	//读出数据库
	iot_redis_get(key string)
	//查询数据库
	iot_redis_query(key string) bool
	//断开数据库
	iot_redis_disconnect()
}

func (redis_struct *redis_var) iot_redis_connect() {
	redis_struct.c_status = 0
	redis_struct.c, redis_struct.err = redis.Dial("tcp", "127.0.0.1:6379")
	if redis_struct.err != nil {
		fmt.Println(redis_struct.err)
		return

	}
	redis_struct.c_status = 1
	fmt.Printf("init ok\n")
	defer redis_struct.c.Close()
}

func (redis_struct *redis_var) iot_redis_set(key string, msg string) {
	if 1 == redis_struct.c_status {
		redis_struct.c.Do("SET", key, msg)
	}
}

func (redis_struct *redis_var) iot_redis_get(key string) {
	// if 1 == redis_struct.c_status {
	// 	v, err = redis.Strings(redis_struct.c.Do("GET", key))
	// 	if err != nil {
	// 		fmt.Println(err)
	// 		return
	// 	}
	// 	return
	// }
	// return
}
func (redis_struct *redis_var) iot_redis_query(key string) bool {

	return true
}
func (redis_struct *redis_var) iot_redis_disconnect() {
	redis_struct.c.Close()
	redis_struct.c_status = 0
}
